package com.lili.collection.core.support;

import com.lili.collection.core.domain.RunnerMsgTransfer;

/**
 *描述: 前置处理
 *@date:2023/3/16  16:55
 *@author:lili
 */
public interface PreHandleSupport {

    /**
     * 前置处理
     */
    default void preHandle(){};

    /**
     * 查询初始化偏移量
     * @return
     */
    default String queryInitialOffset(){return null;}

    /**
     * 运行状态传递
     * @param transfer
     */
    default void setRunnerTransfer(RunnerMsgTransfer transfer){}

    /**
     * 获取运行状态传递
     */
    default RunnerMsgTransfer getRunnerTransfer(){return null;}

    /**
     * 获取删除偏移数
     * @return
     */
    default int getDeleteOffsetNum(){return 0;}
}